package com.hujf.flink.ProcessApi;

import org.apache.flink.api.common.eventtime.WatermarkStrategy;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Author hujf
 * @Date 2022/3/24 16:38
 * @Description TODO
 */
public class ProcessFunctionTest {
    public static void main(String[] args) {
//        StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
//        environment.setParallelism(1);
//        environment.addSource(new ClickSource).assignTimestampsAndWatermarks(WatermarkStrategy.forBoundedOutOfOrderness())

        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(123);
            }
        });
        thread.setDaemon(true);
        thread.start();

    }
}
